import org.apache.spark.{SparkConf, SparkContext}

/**
  * @Title:
  * @ProjectName
  * @Description:
  * @author 郭朋朋
  */


object wk {
  def main(args: Array[String]): Unit = {
//    配置 信息  在哪里运行  起的名字
    val conf = new SparkConf().setMaster("local").setAppName("wk")
//入口
    val sp = new SparkContext(conf)
//读
    //           flatMap 就是压平 （<这个就是匿名内部类>）进行切分
    // 接着，需要将每一个单词，映射为(单词, 1)的这种格式
    // 相加
//    循环
//    关闭一下
    sp.textFile("f:\\b.txt").flatMap(x => x.split(" ")).map(x=>(x,1)).reduceByKey(_+_).foreach(println)

    sp.stop()

  }

}
